package com.jinyuanchun.learnjava.controller.pms;

import com.jinyuanchun.learnjava.message.EmployMsg;
import com.jinyuanchun.learnjava.service.ProduceService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class RawdataController {
    @Autowired
    ProduceService produceService;

    @PostMapping("/pms/rawdata/{sub}")
    public Object judge() {
        String sub = "sub1";
        String topic = "gbk_rawdata";
        EmployMsg msg = new EmployMsg();
        produceService.addMessage(topic,msg);
        return "ok";
    }
}
